package com.intellif.mozping.producer;


import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.validation.annotation.Validated;

/**
 * kafka消费者配置
 *
 * @author liuzj
 * @date 2019-01-08
 */

@Validated
@Data
@Configuration
public class KafkaProducerConfig {

    @Value("${cluster.topics}")
    private String topics;

    @Value("${cluster.bootstrap.servers}")
    private String bootstrapServers;
    @Value("${cluster.acks}")
    private String acks;

    @Value("${cluster.retries}")
    private String retries;
    @Value("${cluster.batch.size}")
    private String batchSize;

    @Value("${cluster.linger.ms}")
    private String lingerMs;
    @Value("${cluster.buffer.memory}")
    private String bufferMemory;

    @Value("${cluster.key.serializer}")
    private String keySerializer;
    @Value("${cluster.value.serializer}")
    private String valueSerializer;


}
